package edu.cmu.arch.pipesandfilters;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * 
 * @author Steven Thomas (steventh@andrew.cmu.edu)
 */
public abstract class OutputFilterFramework extends FrameFilterFramework {
	
	private BlockingQueue<Object> queue = new LinkedBlockingQueue<Object>();
	
	public boolean putMessage(Object o)
	{
		return queue.add(o);
	}
	
	public Object pollMessage()
	{
		return queue.poll();
	}

}
